package com.bw.medical.realtime.common.constant;

public class Constant {
//    kafka
//    public static final String KAFKA_BROKERS = "hadoop103:9092,hadoop104:9092,hadoop105:9092";
    public static final String KAFKA_BROKERS = "hadoop101:9092,hadoop102:9092,hadoop103:9092";
    public static final String TOPIC_DB = "topic_db";
    public static final String TOPIC_LOG = "topic_log";


//    mysql
    public static final String MYSQL_HOST = "hadoop101";
    public static final int MYSQL_PORT = 3306;

    public static final String MYSQL_DRIVER = "com.mysql.cj.jdbc.Driver";
    public static final String MYSQL_URL = "jdbc:mysql://hadoop101:3306?useSSL=false";

    public static final String MYSQL_USER_NAME = "root";
    public static final String MYSQL_PASSWORD = "root";
    public static final String PROCESS_DATABASE = "medical_config";
    public static final String PROCESS_DIM_TABLE_NAME = "table_process";
    public static final String PROCESS_DWD_TABLE_NAME = "table_process_dwd";


//    hbase
    public static final String HBASE_ZOOKEEPER_QUORUM = "hadoop101,hadoop102,hadoop103";
    public static final String HBASE_NAMESPACE = "medical_realtime";
//    redis

//    kafka主题为topic_log topic_db
//    kafka设计为每一层一个主题   表名为组id 也就是组名称
//    ods

//    dim

//    dwd

//    dws

//    ads

}
